package datasource

import org.apache.flink.streaming.api.scala._

object CollectionStream {
  /**
    * 从集合获取数据源
    * @param list
    * @param env
    * @return
    */
  def getCollectionStream(list: List[String], env: StreamExecutionEnvironment): DataStream[String] =
    env.fromCollection(list)
}
